package com.fs.common.config;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * 通知处理服务
 * 主要用于当管理员进行设备等更新操作时，通知各数据处理节点进行缓存刷新操作
 *
 * @author  LiuQi 2025/3/30-10:16
 * @version V1.0
 **/
public interface NoticeProcessor {
    /**
     * 处理Kafka通知消息
     */
    void process(ConsumerRecord<String, String> record);
}
